2a0c08b27355eb6035bf4551ea6207b4a440ecd4,central/src/main/java/org/glowroot/central/GrpcServer.java,CollectorServiceImpl,collectGaugeValues,#GaugeValueMessage#StreamObserver#,305

Before Change


                StreamObserver<EmptyMessage> responseObserver) {
            long maxCaptureTime = 0;
            try {
                gaugeValueDao.store(request.getAgentId(), request.getGaugeValuesList());
                for (GaugeValue gaugeValue : request.getGaugeValuesList()) {
                    maxCaptureTime = Math.max(maxCaptureTime, gaugeValue.getCaptureTime());
                }
            } catch (Throwable t) {
                logger.error("{} - {}", request.getAgentId(), t.getMessage(), t);
                responseObserver.onError(t);
                return;
            }
            try {
                heartbeatDao.store(request.getAgentId());
            } catch (Throwable t) {
                logger.error("{} - {}", request.getAgentId(), t.getMessage(), t);
                responseObserver.onError(t);
                return;
            }
            String agentDisplay = agentDao.readAgentRollupDisplay(request.getAgentId());
            checkGaugeAlerts(request.getAgentId(), agentDisplay, maxCaptureTime);
            clearHeartbeatAlerts(request.getAgentId(), agentDisplay);
            responseObserver.onNext(EmptyMessage.getDefaultInstance());
            responseObserver.onCompleted();

After Change


        @Override
        public void collectGaugeValues(GaugeValueMessage request,
                StreamObserver<EmptyMessage> responseObserver) {
            String agentId = request.getAgentId();
            long maxCaptureTime = 0;
            try {
                gaugeValueDao.store(agentId, request.getGaugeValuesList());